<?php

/**
 *
 * 回调基础类
 * @author Zhang Xingliang
 *
 */
class QHNotify extends QHNotifyReply
{
    private $config = null;

    /**
     * 回调入口
     * @param QHConfigInterface $config 配置对象
     * @param bool $needSign 是否需要签名返回
     * @throws QHException
     */
    final public function Handle($config, $needSign = true)
    {
        $this->config = $config;
        $msg = "成功";
        //获取通知的数据 获取请求体内容 json 文本
        $jsonStr = isset($GLOBALS['HTTP_RAW_POST_DATA']) ? $GLOBALS['HTTP_RAW_POST_DATA']
            : file_get_contents("php://input");
        if (empty($jsonStr)) {
            # 如果没有数据，直接返回失败
            $result = false;
        } else {
            $this->fromJson($jsonStr);
            $result = $this->NotifyProcess($this, $config, $msg);
        }
        if ($result == false) {
            $this->setCode(-1);
            $this->setMsg($msg);
            $this->ReplyNotify(false);
            return;
        } else {
            //该分支在成功回调到NotifyCallBack方法，处理完成之后流程
            $this->setCode(200);
            $this->setMsg("成功");
        }
        $this->ReplyNotify($needSign);
    }

    /**
     *
     * 回调方法入口，子类可重写该方法
     * 注意：
     * 1、千禾回调超时时间为2s，建议用户使用异步处理流程，确认成功之后立刻回复千禾服务器
     * 2、千禾服务器在调用失败或者接到回包为非确认包的时候，会发起重试，需确保你的回调是可以重入
     * @param QHNotify $objData 回调解释出的参数
     * @param QHConfigInterface $config
     * @param string $msg 如果回调处理失败，可以将错误信息输出到该方法
     * @return bool true回调出来完成不需要继续回调，false回调处理未完成需要继续回调
     */
    public function NotifyProcess($objData, $config, &$msg)
    {
        /*
         * TODO 用户基础该类之后需要重写该方法，成功的时候返回true，失败返回false
         * TODO 1、进行参数校验
         * TODO 2、进行签名验证
         * TODO 3、处理业务逻辑
         */
        return false;
    }

    /**
     *
     * 业务可以继承该方法，打印JSON方便定位.
     * @param string $jsonData 返回的json参数
     *
     **/
    public function LogAfterProcess($jsonData)
    {
        return;
    }

    /**
     *
     * 回复通知
     * @param bool $needSign 是否需要签名输出
     */
    final private function ReplyNotify($needSign = true)
    {
        //如果需要签名
        if ($needSign == true && $this->getCode() == 200) {
            $this->setSign($this->config);
        }

        $data = $this->toJSONString();
        $this->LogAfterProcess($data);
        QHApi::replyNotify($data);
    }
}
